package com.example.springboot.controller;

import cn.hutool.core.io.FileUtil;
import cn.hutool.core.util.IdUtil;
import cn.hutool.core.util.StrUtil;
import cn.hutool.crypto.SecureUtil;
import cn.hutool.json.JSONUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.example.springboot.entity.Files;
import com.example.springboot.mapper.FileMapper;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;

import javax.annotation.Resource;
import javax.servlet.ServletOutputStream;
import javax.servlet.http.HttpServletResponse;
import java.io.File;
import java.io.IOException;
import java.net.URLEncoder;
import java.util.List;

@RestController
@RequestMapping("/file")
public class FileController {

    @Value("${files.upload.path}")
    private String fileUploadPath;

    @Value("${server.ip}")
    private String serverIp;

    @Resource
    private FileMapper fileMapper;


    /**
     * 文件上传接口
     *
     * @return file 前端传递通过来的文件
     * @throws IOException
     */

    @PostMapping("upload")
    public String upload(@RequestParam MultipartFile file) throws IOException {

        String originalFilename = file.getOriginalFilename(); //获取原始名称
        String type = FileUtil.extName(originalFilename);  //获取文件类型
        long size = file.getSize();   //获取文件大小

        //定义一个文件唯一的标识码
        String uuid = IdUtil.fastSimpleUUID();
        //StrUtil.DOT 是.的意思
        String fileUUID = uuid + StrUtil.DOT + type; //文件类型

        File uploadFile = new File(fileUploadPath + fileUUID);

        //父级目录是否存在，若不存在创建一个files文件目录
        File parentFile = uploadFile.getParentFile();
        if (!parentFile.exists()) {
            parentFile.mkdir();
        }

        //获取文件的url
        String url;
        //上传文件的磁盘
        file.transferTo(uploadFile);

        //获取文件的md5，通过对比md5文件避免重复上传相同内容的文件
        String md5 = SecureUtil.md5(uploadFile);

        //从数据库查询，是否存在相同 的记录，getFileByMd5（封装方法）
        Files dbFiles = getFileByMd5(md5);

        //判断是否有相同图片
        if (dbFiles != null) {
            //如果存在就用数据库的url
            url = dbFiles.getUrl();
            //由于文件已存在，所以上传刚才上传的重复文件
            uploadFile.delete();
        } else {
            url = "http://" + serverIp + ":8081/file/" + fileUUID;
        }

        //存储到数据库
        Files saveFile = new Files();
        saveFile.setName(originalFilename);
        saveFile.setType(type);
        saveFile.setSize(size / 1024);
        saveFile.setUrl(url);
        saveFile.setMd5(md5);
        fileMapper.insert(saveFile);
        return url;
    }

    @PostMapping("uploadImg")
    public Object uploadImg(@RequestParam MultipartFile file) throws IOException {

        String originalFilename = file.getOriginalFilename(); //获取原始名称
        String type = FileUtil.extName(originalFilename);  //获取文件类型
        long size = file.getSize();   //获取文件大小

        //定义一个文件唯一的标识码
        String uuid = IdUtil.fastSimpleUUID();
        //StrUtil.DOT 是.的意思
        String fileUUID = uuid + StrUtil.DOT + type; //文件类型

        File uploadFile = new File(fileUploadPath + fileUUID);

        //父级目录是否存在，若不存在创建一个files文件目录
        File parentFile = uploadFile.getParentFile();
        if (!parentFile.exists()) {
            parentFile.mkdir();
        }

        //获取文件的url
        String url;
        //上传文件的磁盘
        file.transferTo(uploadFile);

        //获取文件的md5，通过对比md5文件避免重复上传相同内容的文件
        String md5 = SecureUtil.md5(uploadFile);

        //从数据库查询，是否存在相同 的记录，getFileByMd5（封装方法）
        Files dbFiles = getFileByMd5(md5);

        //判断是否有相同图片
        if (dbFiles != null) {
            //如果存在就用数据库的url
            url = dbFiles.getUrl();
            //由于文件已存在，所以上传刚才上传的重复文件
            uploadFile.delete();
        } else {
            url = "http://" + serverIp + ":8081/file/" + fileUUID;
        }

        //存储到数据库
        Files saveFile = new Files();
        saveFile.setName(originalFilename);
        saveFile.setType(type);
        saveFile.setSize(size / 1024);
        saveFile.setUrl(url);
        saveFile.setMd5(md5);
        fileMapper.insert(saveFile);

        // {
//   "errno":0,
//       "data":[
//         {
//           url: "图片地址",
//         }
//      ]
// }

        return JSONUtil.parseObj("{\"errno\": 0, \"data\": [{\"url\": \"" + url + "\"}]}");
    }

    /**
     * 通过文件md5查询文件
     *
     * @param md5
     * @return
     */
    private Files getFileByMd5(String md5) {
        //查询文件的md5是否存在
        QueryWrapper<Files> queryWrapper = new QueryWrapper<>();
        queryWrapper.eq("md5", md5);
        List<Files> filesList = fileMapper.selectList(queryWrapper);
        return filesList.size() == 0 ? null : filesList.get(0);

    }

    /**
     * http://localhost:8081/file/{fileUUID}
     * 下载文件接口
     */
    @GetMapping("/{fileUUID}")
    public void download(@PathVariable String fileUUID, HttpServletResponse response) throws IOException {
        // 根据文件的唯一标识吗获取文件
        File uploadFile = new File(fileUploadPath + fileUUID);
        // 数组输出流的格式
        ServletOutputStream os = response.getOutputStream();
        response.addHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode(fileUUID, "UTF-8"));
        response.setContentType("application/octet-stream");

        //读取文件的字节流
        os.write(FileUtil.readBytes(uploadFile));
        os.flush();
        os.flush();
    }
}
